package com.vcredit.creditcat.service;

import com.vcredit.framework.bean.MsgBean;
import com.vcredit.framework.interceptor.SendAdvice;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;


/**
 * Created by liaoshengjun on 2017/7/25.
 */
@Component
@Service
public class ClickLogProducerService {
	@Autowired
	private SendAdvice kafka;

	public void setClickData(Long custId,String logType,String data){
		MsgBean msgBean=new MsgBean();
		msgBean.put("clickLogData",data);
		msgBean.put("custId",custId);
		msgBean.put("logType",logType);
		msgBean.setTopic("clicklog");
		kafka.addMessage(msgBean);
	}
}
